# -*- coding: utf-8 -*-
# @Author  : Pony
# @Time    : 2021/10/26 下午2:45

import time
import json
from business.redis_demo import RedisHelper

obj = RedisHelper(channel_name='to_server_1635497258834')
redis_sub = obj.subscribe()
# while True:
#     # listen()函数封装了parse_response()函数
#     print(1234)
#     msg = redis_sub.listen()
#     time.sleep(3)
#     for i in msg:
#         if i["type"] == "message":
#             msg = str(i["data"], encoding="utf-8")
#             msg = json.loads(msg)
#             print(msg)

msg = redis_sub.listen()
for i in msg:
    if i["type"] == "message":
        msg = str(i["data"], encoding="utf-8")
        msg = json.loads(msg)
        print(msg)
        # redis_sub.unsubscribe("to_server_1635318358758")


print(123)




